//package com.wxl.rocketmq.test.controller;
//
//import com.wxl.rocketmq.test.produce.MessageProducer;
//import org.springframework.beans.factory.annotation.Autowired;
//import org.springframework.web.bind.annotation.GetMapping;
//import org.springframework.web.bind.annotation.PathVariable;
//import org.springframework.web.bind.annotation.RestController;
//
//@RestController
//public class MqController {
//
//    @Autowired
//    private MessageProducer messageProducer;
//
//    @GetMapping("/send/msg/{id}")
//    public String send(@PathVariable("id") Integer id){
//
//        if(id==1){
//            messageProducer.sendMessage("sample-topic",System.currentTimeMillis()+"==");
//        }
//
////        else if(id==2){
////            messageProducer.sendMessageWithTag("test-tag-topic","TAGA",System.currentTimeMillis()+"==");
////        }else {
////            messageProducer.sendDelayMessage("test-delay-topic",System.currentTimeMillis()+"==",4);
////        }
//
//        return "succ";
//    }
//
//
//
//}
